package m_simple;

import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;

import java.io.IOException;
import java.util.concurrent.TimeoutException;

public class Producer {
    public static void main(String[] args) throws IOException, TimeoutException {
        //创建连接工厂,设置连接的信息,  创建通道

        ConnectionFactory f =new ConnectionFactory();
                f.setHost("192.168.64.140");//主机
                f.setPort(5672);//端口
                f.setUsername("admin");
                f.setPassword("admin");
            //  创建连接
        Connection con = f.newConnection();
        //通过连接获取通信通道
        Channel c = con.createChannel();

        //定义队列 队列有多个需要自定义队列的名字,这个方法是告诉mq服务器我们要使用哪个队列
          //参数意思 : 定义队列的名字, 队列是否持久化,排他性(是不是只有自己可以连),当最后一个消费者断开连接是否删除队列,其他参数
            c.queueDeclare("hell", false, false, false, null);
        //发送消息
        //参数意思:交换机的名称空串代表默认,对于默认的交换机路由键就死队列的名字,其他参数,消息内容
            c.basicPublish("", "hell", null, "hell world".getBytes());
        System.out.println("消息以发送");

            //断开连接
        c.close();
        con.close();
    }
}
